---
id: 207
title: Mqtt采集
---

import useBaseUrl from "@docusaurus/useBaseUrl";
import Tag from "@site/src/components/Tag.js";
import Highlight from '@site/src/components/Highlight.js';


## 一、说明

MqttCollect 驱动程序可用于从属设备获取通过 MQTT 协议发送的数据。变量地址中指定主题。当接收到这些主题的更新时，会对负载进行分析，并更新变量值

通讯链路支持 Other

## 二、插件属性配置项

| 属性           |  说明                    | 备注|
| ---------------| --------------------------| ---|
| IP         | ServerIP,为空时指任意IP              | |
| 端口         | 连接端口              | 1883|
| 是否WebSocket连接         | 是否WebSocket连接             | False |
| WebSocketUrl         | WebSocketUrl             | ws://127.0.0.1:8083/mqtt |
| 账号         | 账号             |  |
| 密码         | 密码              |  |
| 连接Id         | 连接Id              |  |
| 连接超时时间         | 连接超时时间              |  |

## 三、变量地址配置项


变量地址：``${mqtt_topic}+${payload_item}``

主题：``vendor/device``

负载示例：
```
{
    "ModuleUnoccupied": {
        "EquipId":"E12",
        "CarrierId": "C12",
        "SubstrateLocId": "S12",
        "LotId": "L12",
        "DesignId": "D12",
        "EventTime": "12322131"
    }
}
```

比如 ``vendor/device+ModuleUnoccupied.EquipId``，结果是 ``"E12"``